package com.netty.rpc.protocol.client;

import com.netty.rpc.common.entity.NettyRpcRequest;
import io.netty.channel.ChannelFuture;


public interface IRequsetInterceptor {

    // 异步调用
    void invokeAsync(ChannelFuture channelFuture, NettyRpcRequest request) throws Exception;

    // 同步调用
    Object invokeSync(ChannelFuture channelFuture, NettyRpcRequest request) throws Exception;

}
